package com.shanks.framework.mq.service;

import com.shanks.framework.mq.model.MessageRecordPO;

import java.util.List;

/**
 * 消息队列服务类
 */
public interface MessageQueueService {
    /**
     * 插入本地消息并入队
     *
     * @param messageRecordPO
     * @throws Exception
     */
    void insertAndOfferMessage(MessageRecordPO messageRecordPO);

    /**
     * 批量插入本地消息并入队
     *
     * @param messageRecordPOList
     * @throws Exception
     */
    void insertAndOfferBatchMessages(List<MessageRecordPO> messageRecordPOList);
}
